package cn.example.vip.mall.canal.job;

import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.simple.SimpleJob;
import com.dangdang.elasticjob.lite.annotation.ElasticSimpleJob;

/**
 * 设置:
 * 1.任务周期
 * 2.分片
 * 3.指定 zookeeper 的命名空间
 */
//@Component
@ElasticSimpleJob(
	jobName = "${elaticjob.zookeeper.namespace}", // elasticJob 的配置
	shardingTotalCount = 1,		// 分片
	cron = "0/5 * * * * ? *"	// 执行周期(每秒钟执行一次)
)
public class StaticJob implements SimpleJob {
	
	/**
	 * 定时任务的具体方法
	 * @param shardingContext
	 */
	@Override
	public void execute(ShardingContext shardingContext) {
		System.out.println("StaticJobTask--execute");
	}
	
	/*
	* 注册同步周期任务
	* 1.注册任务->zookeeper
	* 2.创建 Task 配置
	* 	a.JobName	// elasticJob命名空间
	* 	b.shardingTotalCount	// 分片
	* 	c.cron	// 执行周期
	* 3.创建任务
	* 4.初始化并启动任务
	* */
	
}
